/**
 * 文件名：@T_amqp.java <br/>
 * 包名：cn.efunbox.afw.data.test <br/>
 * 项目名：afw-data <br/>
 * @author xtwin <br/>
 */
package cn.efunbox.afw.data.test;

/**
 * 类名：T_amqp  <br />
 *
 * 功能：
 *
 * @author xtwin <br />
 * 创建时间：2016年8月8日 下午12:22:14  <br />
 * @version 2016年8月8日
 */
public class T_amqp {
	
	/**
	 * 功能：消息接收 <br/>
	 *
	 * @author xtwin <br/>
	 * @version 2016年8月8日 下午2:20:15 <br/>
	 */
//	@Test
//	public void _02() throws Exception {
//		Channel channel = getConnection().createChannel();
//		
//		channel.exchangeDeclare("EX.Test.xt", "topic", true);
//		
//		channel.queueDeclare("QE.Test.xt", true, false, false, null);
//		
//		channel.queueBind("QE.Test.xt", "EX.Test.xt", "RT.Test.xt");
//		
//		QueueingConsumer consumer = new QueueingConsumer(channel);
//		
//		channel.basicConsume("QE.Test.xt", consumer);
//		
//		while (true) {
//			Delivery delivery = consumer.nextDelivery();
//			
//			String message = new String(delivery.getBody(), "UTF-8");
//			
//			// 确认消息
//			channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);
//			
//			System.out.println("the message is : " + message);
//		}
//	}
//
//	/**
//	 * 功能：消息发送 <br/>
//	 *
//	 * @author xtwin <br/>
//	 * @version 2016年8月8日 下午2:19:59 <br/>
//	 */
//	@Test
//	public void _01() throws Exception {
//		// 创建渠道
//		Channel channel = getConnection().createChannel();
//		
//		// 渠道绑定
//		channel.exchangeDeclare("EX.Test.xt", "topic", true);
//		
//		AMQP.BasicProperties.Builder builder = new AMQP.BasicProperties.Builder()
//                .contentType("text/plain")
//                .contentEncoding("UTF-8")
//                .deliveryMode(2)
//                .priority(0);
//		
//        AMQP.BasicProperties properties = builder.build();
//        
//        channel.basicPublish("EX.Test.xt", "RT.Test.xt", properties, "Hello world0.".getBytes("UTF-8"));
//        channel.close();
//	}
//	
//	//@Before
//	public Connection getConnection() throws Exception {
//		// 连接工厂
//		ConnectionFactory factory = new ConnectionFactory();
//		
//		factory.setHost("192.168.60.203");
//		factory.setPort(5672);
//		factory.setUsername("acfun");
//		factory.setPassword("3v9V0NmShY5U");
//		factory.setAutomaticRecoveryEnabled(true);
//		factory.setTopologyRecoveryEnabled(true);
//		
//		return factory.newConnection();
//	}
}






























